package club.vann.kafka.mock.kafka;

/** 系统topic常量字符串（包括kafka和websocket） */
public class ConstantTopic {
  /** acceptor input topic */
  public static final String TOPIC_ACCEPTOR_INPUT = "acceptor.input";

  /** acceptor output topic */
  public static final String TOPIC_ACCEPTOR_OUTPUT = "acceptor.output";

  /** 行情数据的topic */
  public static final String TOPIC_MARKET_PRICE_SUMMARY_OUTPUT = "market.price.summary.output";

  /** pair summary topic */
  public static final String TOPIC_PERP_PAIR_SUMMARY_OUTPUT = "perp.pair.summary.inventory.output";

  /** 报价操作结果 topic */
  public static final String TOPIC_QUOTE_ACTION_OUTPUT = "quote.action.output";

  /** 报价市场行情 Topic */
  public static final String TOPIC_QUOTE_MARKET_OUTPUT = "quote.market.output";

  /** 波动率数据 topic */
  public static final String TOPIC_REALIZED_VOLATILITY_INPUT = "realized.volatility.input";

  /** 策略汇总 Topic */
  public static final String TOPIC_STRATEGY_SUMMARY_OUTPUT = "strategy.summary.output";

  /** 动态表格topic */
  public static final String TOPIC_TABLE_DATA_OUTPUT = "table.data.output";

  /** 成交事件topic */
  public static final String TOPIC_TRADE_EVENT_OUTPUT = "cex.order_event.output.FULL_EXEC.ZHOUYI";

  /** zhouyi系统重启信息的 Topic */
  public static final String TOPIC_ZHOUYI_INIT_OUTPUT = "zhouyi.init.output";

  /** 策略父级动作 Output */
  public static final String TOPIC_STRATEGY_PARENT_ACTION_OUTPUT = "strategy.parent.action.output";

  public static final String TOPIC_TRANSFER_OUTPUT = "transfer.output";

  private ConstantTopic() {}
}
